30acc60676ba9362ddb9b74f208b36d257a78f93,kafka-scheduler/src/main/java/com/mesosphere/dcos/kafka/offer/PersistentOfferRequirementProvider.java,PersistentOfferRequirementProvider,updateMem,#TaskInfo.Builder#BrokerConfiguration#,214
Before Change
}
private TaskInfo.Builder updateMem(TaskInfo.Builder taskBuilder, BrokerConfiguration brokerConfig) {
ValueBuilder valBuilder = new ValueBuilder(Value.Type.SCALAR);
valBuilder.setScalar(brokerConfig.getMem());
return updateValue(taskBuilder, "mem", valBuilder.build());
}
private TaskInfo.Builder updateDisk(TaskInfo.Builder taskBuilder, BrokerConfiguration brokerConfig) {
After Change
}
private TaskInfo.Builder updateMem(TaskInfo.Builder taskBuilder, BrokerConfiguration brokerConfig) {
return updateValue(taskBuilder, "mem", scalar(brokerConfig.getMem()));
}
private TaskInfo.Builder updateDisk(TaskInfo.Builder taskBuilder, BrokerConfiguration brokerConfig) {